/*
 * Copyright (c) 2019 Nanjing Wind Information Co., Ltd. All Rights Reserved;
 * @Package wind.autotest.web
 * @version 1.0.0
 * @Date 2019年4月19日
 * @author jlliu.Farrior@wind.com.cn
 */
package wind.autotest.web;

import java.util.List;
import java.util.Set;

import javax.servlet.http.HttpServletRequest;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;








import wind.autotest.database.suport.DatabaseContextHolder;
import wind.autotest.pojo.TestTable;
import wind.autotest.service.backend.EtlService;
import wind.autotest.util.FileUtil;
import wind.autotest.util.Page4Navigator;

/**
 * @Description: <样本管理>
 * @author jlliu.Farrior@wind.com.cn
 * @Date 2019年4月19日 下午8:10:41
 * 
 */
@Slf4j
@RestController
public class SampleListControl {
	
	@Autowired
	private EtlService etlService;
	
	
	@PostMapping("/sampleManager")
	public Object add(String taskId,String database, MultipartFile txtfile, HttpServletRequest request) throws Exception {
		if (null == txtfile) {
			log.warn("上传文件为空");
			return null;
		}
		// 设置数据库站点：
		DatabaseContextHolder.setDatabase(database);
		
		// 获取样本记录ID
		List<String> sampleRecordIds = FileUtil.getSampleRecordIds(txtfile.getInputStream());
		// 查询数据库 读取主表样本数据
		Set<String> addSampleNames   = etlService.getDataByRowIds(sampleRecordIds, taskId);
		// 读取已经存在的
		Set<String> existSampleNames = etlService.getDataByRowIds(sampleRecordIds, taskId);
		// 保存质检样本
		
		// 显示样本数据
		
		
		
//		// 读取样本记录
//		// 主表配置
//		TableConfDTO mainTbConf = tbConfService.getMainConfTable(taskId);
//		if (null == mainTbConf) {
//			log.error("主表配置为空 taskid={}",taskId);
//		}
//		// 主键
//		String mainfieldconf = mainTbConf.getMainFields();
//		// 关联键
//		String relatedfieldconf = mainTbConf.getRelatFields();
//		
//		// 默认展示主表
//		List<FieldValue> mainfields = FieldUtil.getFields(mainfieldconf, "main");
//		// 查询
//		SelectedRecords records = dbQueryTool.getRecordsListByObjectIDs(
//				new QueryParam.Builder(mainTbConf.getTableName(), mainfields)
//						.builder(), sampleRecordIds);
//		
//		// 更新样本
//		SelectedRecords updatedRecords = dataPersistent.updateSampleDataKey(taskId,records);
		
		// 查询样本数据 
		
		
		return null;
	}
	

}
